package activemqDemo;

import org.slf4j.Logger;  
import org.slf4j.LoggerFactory;  
  
import javax.jms.JMSException;  
import javax.jms.Message;  
import javax.jms.MessageListener;  
import javax.jms.TextMessage;  
  
/** 
 * 消费者监听类 
 * 具体的消息消费类，可以在这实现具体的业务逻辑处理 
 */  
public class ConsumerMessageListener implements MessageListener {  
    private Logger logger = LoggerFactory.getLogger(this.getClass());  
  
    /** 
     * 监听发送到消息队列的文本消息 
     * @param message 
     */  
    @Override  
    public void onMessage(Message message) {  
        TextMessage textMessage = (TextMessage) message;  
        try {  
            System.out.println("接收到的消息内容是：" + textMessage.getText());  
        } catch (JMSException e) {  
            logger.error("消息解析失败", e);  
        }  
    }  
  
}  
